package cn.com.netedge.iot.protocol.utils;

import cn.com.netedge.iot.common.mq.MqMessageListener;
import cn.com.netedge.iot.common.utils.BaseJmsMsgUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.stereotype.Component;

@Component("protocolJmsMsgUtil")
@RefreshScope
public class JmsMsgUtil extends BaseJmsMsgUtil {
    private static final Logger logger = LoggerFactory.getLogger(JmsMsgUtil.class);

    @Override
    public void subscribeQueues() {
    }

    @Override
    public MqMessageListener getMessageListener(String queueName) {
        logger.debug("queueName:{} not support subscribe");
        return null;
    }


}
